package com.gxd.esimport;

import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

public class pipe {

    public static AtomicInteger atomic = new AtomicInteger(0);
    public  LinkedBlockingQueue<Map<String, Object>> simpleArrayConcurrentQueue = new LinkedBlockingQueue(60000);
    public  ExecutorService inputExecutorService = new ThreadPoolExecutor(10, 20000, 10, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(20000));
    public  ExecutorService outputExecutorService = new ThreadPoolExecutor(3, 5, 10, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(5));

}
